Crate influxdb

This library is a work in progress. Although we've been using it in production at OpenVelo, we've prioritized features that fit our use cases. This means a feature you might need is not implemented yet or could be handled better.

Pull requests are always welcome. See Contributing and Code of Conduct.

Currently Supported Features

• Reading and Writing to InfluxDB
• Optional Serde Support for Deserialization
• Running multiple queries in one request (e.g. SELECT * FROM weather_berlin; SELECT * FROM weather_london)
• Authenticated and Unauthenticated Connections
• Optional conversion between Timestamp and Chrono::DateTime<Utc> via chrono_timestamps compilation feature
• async/await support

Planned Features

• Read Query Builder instead of supplying raw queries
• #[derive(InfluxDbReadable)] and #[derive(InfluxDbWriteable)] proc macros

Quickstart

Add the following to your Cargo.toml

influxdb = "0.0.6"

For an example with using Serde deserialization, please refer to serde_integration

use influxdb::{Client, Query, Timestamp};

// Create a Client with URL `http://localhost:8086`
// and database name `test`
let client = Client::new("http://localhost:8086", "test");

// Let's write something to InfluxDB. First we're creating a
// WriteQuery to write some data.
// This creates a query which writes a new measurement into a series called `weather`
let write_query = Query::write_query(Timestamp::Now, "weather")
    .add_field("temperature", 82);

// Submit the query to InfluxDB.
let write_result = client.query(&write_query).await;
assert!(write_result.is_ok(), "Write result was not okay");

// Reading data is as simple as writing. First we need to create a query
let read_query = Query::raw_read_query("SELECT * FROM weather");

// submit the request and wait until it's done
let read_result = client.query(&read_query).await;

assert!(read_result.is_ok(), "Read result was not ok");

// We can be sure the result was successful, so we can unwrap the result to get
// the response String from InfluxDB
println!("{}", read_result.unwrap());

For further examples, check out the Integration Tests in tests/integration_tests.rs in the repository.

License

Modules

integrations

Structs

Client	Internal Representation of a Client
ReadQuery
WriteQuery	Internal Representation of a Write query that has not yet been built

Enums

Error
QueryType	Internal Enum used to decide if a POST or GET request should be sent to InfluxDB. See InfluxDB Docs.
QueryTypes	Internal enum used to represent either type of query.
Timestamp
Type

Traits

Query